package com.atguigu.gmall.activity.redis;

import com.atguigu.gmall.activity.util.CacheHelper;
import org.apache.commons.lang.StringUtils;
import org.springframework.stereotype.Component;

/**
 * @author fxz
 */
@Component
public class MessageReceive {

	/**
	 * 接收消息的方法
	 */
	public void receiveMessage(String message) {
		System.out.println("----------收到消息了message：" + message);
		if (!StringUtils.isEmpty(message)) {
			/*
			 * 消息格式 skuId:0 表示没有商品 skuId:1 表示有商品
			 */
			message = message.replaceAll("\"", "");
			String[] split = StringUtils.split(message, ":");

			if (split == null || split.length == 2) {
				assert split != null;
				CacheHelper.put(split[0], split[1]);
			}
		}
	}

}
